package com.lfx.concurrent;

import java.util.Random;

public class ClientThread extends Thread{

    private final Random random;

    private final RequestQueue requestQueue;


    public ClientThread(RequestQueue requestQueue,String name,long seed){
        super(name);
        this.random=new Random(seed);
        this.requestQueue=requestQueue;
    }


    @Override
    public void run() {
        for (int i = 0; i < 10000; i++) {
            Request request = new Request("请求：" + i);
            System.out.println(Thread.currentThread().getName() + " 请求 " +request);
            requestQueue.put(request);
            try {
                Thread.sleep(random.nextInt(1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
